package com.rpcLearning.transport;

import com.rpcLearning.proto.Peer;

import java.io.InputStream;

/**
 * @author:zyh
 * @Time:2021-03-17-18:17
 * @email:1269231889@qq.com
 * 创建连接
 * 发送数据，等待响应
 * 关闭连接
 */
public interface TransportClient {
    void connect(Peer peer);
    InputStream write(InputStream data);
    void close();
}
